from celery_test.celery1 import app


# 启动一个celery worker开始监听，并等待执行任务

if __name__ == '__main__':
    # app.worker_main()
    app.worker_main(argv=['--loglevel=info','-P=eventlet'])

# 在 worker 监听终端（执行过 celery -A tasks worker --loglevel=info 的终端页面），可以看到worker收到并执行了任务。

    '''
    如果执行报错：Task handler raised error: ValueError('not enough values to unpack (expected 3, got 0)')
    安装 pip install eventlet
    
    celery worker -A celery1 -l info -P eventlet    # 启动一个celery worker开始监听，并等待执行任务
    '''